---- 创建一个Stream消息队列
local queueName = ARGV[1]   -- 队列名称
local groupName = ARGV[2]   -- 消费者组名称
-- 判断队列是否存在
if redis.call('exists', queueName) == 0 then
    -- 不存在，创建队列 MKSTREAM：当创建消费者组时，若队列不存在，则将队列和消费者组一起自动创建
    redis.call('xgroup', 'create', queueName, groupName, '0', 'MKSTREAM')
    return 1
end
-- 存在，直接返回0
return 0

